/*
 *
 * Author: Andreas Wüstenberg (andreas.wuestenberg@rwth-aachen.de), Clemens Boennen (clemens.boennen@rwth-aachen.de)
 */

#ifndef RTPS_RECEIVER_H
#define RTPS_RECEIVER_H

#include "rtps/entities/Domain.h"
//#include <vector>

struct Receiver {
    rtps_Domain m_domain;
    Reader *mp_dataReader;
    uint8_t *m_buffer;
};
void Receiver_Init(struct Receiver *pRecv, uint32_t maxMsgSizeInBytes);
void Receiver_run();
void Receiver_prepareRTPS(struct Receiver *pRecv);
//static void Receiver_responderJumppad(struct Receiver *pRecv, void* vp_receiverUnit, ReaderCacheChange *cacheChange);
void Receiver_responderCallback(void *callee, const ReaderCacheChange *cacheChange);
#endif //RTPS_RECEIVER_H
